package com.markhsiu.MiniMQ.client;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

import com.markhsiu.MiniMQ.model.Result;

public class CallBackCache {


    /**
     * 发送消息缓存
     */
    private static final Map<String,Result> callBackMap = new ConcurrentHashMap<String, Result>();
    
    
    //----------- 回调消息管理
    public static  void putCallBack(String messageID,Result result){
        callBackMap.put(messageID,result);
    }

    public static Result getCallBack(String messageID){
        return callBackMap.get(messageID);
    }
 
}
